package com.tianji.aigc.service;

import com.tianji.aigc.dto.ChatDTO;
import com.tianji.aigc.vo.ChatEventVO;
import reactor.core.publisher.Flux;

public interface IChatService {
    /**
     * 创建流式对话
     * @param chatDTO;
     * */
    Flux<ChatEventVO> chat(ChatDTO chatDTO);
    /**
     * 停止会话
     * @param sessionId;
     * */
    void stop(String sessionId);

}
